package org.jeecg.modules.service;

/**
 * 处理MQTT服务连接状态，
 * @author tanxy
 * @date 2022/11/27 21:55
 * @return null
 */
public interface MessageListener {

    /**
     * 处理MQTT服务连接状态，
     *
     * @param connected true：连接正常，false，连接失败
     */
    void handleConnectStatus(boolean connected);

    /**
     * 处理接收的消息
     *
     * @param topic 主题
     * @param msg   消息
     */
    void handleMessage(String topic, byte[] msg);

}
